type google.golang.org/grpc.csAttempt
34 uses
google.golang.org/grpc (current package)
rpc_util.go#L180: after(*callInfo, *csAttempt)
rpc_util.go#L189: func (EmptyCallOption) after(*callInfo, *csAttempt) {}
rpc_util.go#L209: func (o HeaderCallOption) after(c *callInfo, attempt *csAttempt) {
rpc_util.go#L231: func (o TrailerCallOption) after(c *callInfo, attempt *csAttempt) {
rpc_util.go#L253: func (o PeerCallOption) after(c *callInfo, attempt *csAttempt) {
rpc_util.go#L296: func (o FailFastCallOption) after(c *callInfo, attempt *csAttempt) {}
rpc_util.go#L320: func (o MaxRecvMsgSizeCallOption) after(c *callInfo, attempt *csAttempt) {}
rpc_util.go#L344: func (o MaxSendMsgSizeCallOption) after(c *callInfo, attempt *csAttempt) {}
rpc_util.go#L367: func (o PerRPCCredsCallOption) after(c *callInfo, attempt *csAttempt) {}
rpc_util.go#L395: func (o CompressorCallOption) after(c *callInfo, attempt *csAttempt) {}
rpc_util.go#L432: func (o ContentSubtypeCallOption) after(c *callInfo, attempt *csAttempt) {}
rpc_util.go#L471: func (o ForceCodecCallOption) after(c *callInfo, attempt *csAttempt) {}
rpc_util.go#L496: func (o CustomCodecCallOption) after(c *callInfo, attempt *csAttempt) {}
rpc_util.go#L524: func (o MaxRetryRPCBufferSizeCallOption) after(c *callInfo, attempt *csAttempt) {}
stream.go#L323: op := func(a *csAttempt) error {
stream.go#L378: func (cs *clientStream) newAttemptLocked(isTransparent bool) (*csAttempt, error) {
stream.go#L427: return &csAttempt{
stream.go#L437: func (a *csAttempt) getTransport() error {
stream.go#L455: func (a *csAttempt) newStream() error {
stream.go#L540: attempt *csAttempt
stream.go#L544: buffer []func(a *csAttempt) error // operations to replay on retry
stream.go#L550: type csAttempt struct {
stream.go#L595: func (a *csAttempt) shouldRetry(err error) (bool, error) {
stream.go#L693: func (cs *clientStream) retryLocked(attempt *csAttempt, lastErr error) error {
stream.go#L726: func (cs *clientStream) withRetry(op func(a *csAttempt) error, onSuccess func()) error {
stream.go#L775: err := cs.withRetry(func(a *csAttempt) error {
stream.go#L824: func (cs *clientStream) replayBufferLocked(attempt *csAttempt) error {
stream.go#L833: func (cs *clientStream) bufferForRetryLocked(sz int, op func(a *csAttempt) error) {
stream.go#L874: op := func(a *csAttempt) error {
stream.go#L899: err := cs.withRetry(func(a *csAttempt) error {
stream.go#L942: op := func(a *csAttempt) error {
stream.go#L1011: func (a *csAttempt) sendMsg(m interface{}, hdr, payld, data []byte) error {
stream.go#L1038: func (a *csAttempt) recvMsg(m interface{}, payInfo *payloadInfo) (err error) {
stream.go#L1108: func (a *csAttempt) finish(err error) {